import socket 
import time
from concurrent.futures import ThreadPoolExecutor


pool=ThreadPoolExecutor(max_workers=3)

server_addr=('192.168.3.5', 7788)
server_socket=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(server_addr)
server_socket.listen()

def server_send(new_socket):
    while True:
        new_socket.send('a'.encode('utf-8'))
        time.sleep(0.5)        

if __name__=='__main__':
    while True:
        new_socket, addr=server_socket.accept()
        pool.submit(server_send, new_socket)
        time.sleep(0.01)